# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dm.dm_cn_departure_transfer_timely_route_dt import jms_dm__dm_cn_departure_transfer_timely_route_dt
from jms.dwd.oms.dwd_yl_oms_oms_waybill_incre_dt import jms_dwd__dwd_yl_oms_oms_waybill_incre_dt

export_out_departure_transfer_timely_route_detail_oss = BashOperator(
    task_id='export_out_departure_transfer_timely_route_detail_oss',
    email=['shenjiaming@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/export_out_departure_transfer_timely_route_detail_oss/execute.sh',
    execution_timeout=timedelta(minutes=50)
)

export_out_departure_transfer_timely_route_detail_oss << [
    jms_dm__dm_cn_departure_transfer_timely_route_dt,
    jms_dwd__dwd_yl_oms_oms_waybill_incre_dt
]
